package com.changdu.seatunnel.admin.pojo;

import lombok.Data;

@Data
public class KafkaConfig {

    private String kafkaTopic;
    
    private Integer kafkaPartition;	
    
    private String kafkaConsumerGroup;
	
    public static KafkaConfig build(String kafkaTopic, Integer kafkaPartition, String kafkaConsumerGroup) {
    	KafkaConfig kafkaConfig = new KafkaConfig();
    	kafkaConfig.setKafkaTopic(kafkaTopic);
    	kafkaConfig.setKafkaPartition(kafkaPartition);
    	kafkaConfig.setKafkaConsumerGroup(kafkaConsumerGroup);
    	return kafkaConfig;
    }
    
}
